const mysql = require('mysql');

// 连接数据库
const connection = mysql.createConnection({
	host: 'localhost',
	port: '3306',
	user: 'root',
	password: 'root',
	database: 'user_db'
})

connection.connect(function (err) {
	if (err) {
		console.log('数据库连接失败');
	} else {
		console.log('数据库连接成功');
	}
})

// 封装为promise
var dbQuery = function (sqlStr, value) {
	return new Promise(function (reslove, reject) {
		if (value) {
			connection.query(sqlStr, value, function (err, result) {
				if (err) {
					reject(err);
				} else {
					reslove(result);
				}
			})
		} else {
			connection.query(sqlStr, function (err, result) {
				if (err) {
					reject(err);
				} else {
					reslove(result);
				}
			})
		}
	})
}

module.exports = {
	dbQuery
}